package com.saceem.mdb;

import java.io.Serializable;
import java.util.Properties;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class ClienteJMS implements Serializable {

	private static final long serialVersionUID = 1693616289607186982L;

	public static void main(String[] args) throws NamingException, JMSException {
		Properties propiedades = new Properties();
		propiedades.put("java.naming.factory.initial",
				"org.jnp.interfaces.NamingContextFactory");
		propiedades.put("java.naming.factory.url.pkgs",
				"org.jboss.naming:org.jnp.interfaces");
		propiedades.put("java.naming.provider.url", "jnp://localhost:1099");

		Context contexto = new InitialContext(propiedades);
		ConnectionFactory factoria = (ConnectionFactory) contexto
				.lookup("ConnectionFactory");

		Queue queue = (Queue) contexto.lookup("queue/IManagerQueue");
		Connection conexion = factoria.createConnection();
		Session sesion = conexion
				.createSession(false, Session.AUTO_ACKNOWLEDGE);
		MessageProducer productor = sesion.createProducer(queue);
		conexion.start();

		TextMessage mensajeDeTexto = sesion
				.createTextMessage("Mensaje enviado desde Java");
		productor.send(mensajeDeTexto);

		conexion.close();
	}

}
